package com.myself.config;

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;


/**
 * @author W.S.
 * @version v4.0.0
 * @description 队列配置
 * @date Created in 2018/8/21 16:56
 */
@Configuration
public class SenderQueueConfig {


    /**
     * 测试队列 direct
     */
    public static final String TEST_DIREECT_QUEUE = "Q1";

    /**
     * 默认点对点的队列
     * @return
     */
    @Bean
    public Queue testDirectQueue(){
        return new Queue(TEST_DIREECT_QUEUE);
    }

}
